package com.hotpot.quartz;

import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;


/**
 * 描述:定时任务管理器
 * @author myx
 * @date 2017年6月23日 下午5:10:54
 */
public class QuartzManager{
	private Logger log = LogManager.getLogger(QuartzManager.class);

	private Scheduler scheduler = null;
	
	/**
	 * 定义一个静态私有变量(不初始化，不使用final关键字，使用volatile保证了多线程访问时instance变量的可见性，避免了instance初始化时其他变量属性还没赋值完时，被另外线程调用)
	 */
    private static volatile QuartzManager instance;  
	
	public static QuartzManager getIstance() {
		// 对象实例化时与否判断（不使用同步代码块，instance不等于null时，直接返回对象，提高运行效率）
		if (instance == null) {
			// 同步代码块（对象未初始化时，使用同步代码块，保证多线程访问时对象在第一次创建后，不再重复被创建）
			synchronized (QuartzManager.class) {
				// 未初始化，则初始instance变量
				if (instance == null) {
					instance = new QuartzManager();
				}
			}
		}
		return instance;
	}

	/**
	 * @Title:QuartzManager
	 * @Description:构造函数
	 */
	private QuartzManager() {
		try {
			scheduler = new StdSchedulerFactory().getScheduler();
			log.info("初始化调度器 ");
		} catch (SchedulerException ex) {
			log.error("初始化调度器=> [失败]:" + ex.getLocalizedMessage());
		}
	}

	/**
	 * 方法描述：添加任务
	 * @param name 任务名称
	 * @param group 任务组名称
	 * @param clazz 任务操作类
	 * @param cronExpression 定时任务表达式
	 * @return: void
	 */
	public void addJob(String name, String group, Class<? extends Job> clazz,
			String cronExpression) {
		try {
			// 构造任务
			JobDetail job = newJob(clazz).withIdentity(name, group).build();
			// 构造任务触发器
			Trigger trg = newTrigger().withIdentity(name, group).withSchedule(cronSchedule(cronExpression)).build();
			// 将作业添加到调度器
			scheduler.scheduleJob(job, trg);
			log.info("创建作业=> [作业名称：" + name + " 作业组：" + group + "] ");
		} catch (SchedulerException e) {
			e.printStackTrace();
			log.error("创建作业=> [作业名称：" + name + " 作业组：" + group + "]=> [失败]");
		}
	}
	
	/**
	 * 方法描述： 删除任务
	 * @param name  任务名称
	 * @param group 任务组
	 * @return: void
	 */
	public void removeJob(String name, String group) {
		try {
			TriggerKey tk = TriggerKey.triggerKey(name, group);
			scheduler.pauseTrigger(tk);// 停止触发器
			scheduler.unscheduleJob(tk);// 移除触发器
			JobKey jobKey = JobKey.jobKey(name, group);
			scheduler.deleteJob(jobKey);// 删除作业
			log.info("删除作业=> [作业名称：" + name + " 作业组：" + group + "] ");
		} catch (SchedulerException e) {
			e.printStackTrace();
			log.error("删除作业=> [作业名称：" + name + " 作业组：" + group + "]=> [失败]");
		}
	}

	/**
	 * 方法描述：暂停任务
	 * @param name 任务名称
	 * @param group 任务组
	 * @return: void
	 */
	public void pauseJob(String name, String group) {
		try {
			JobKey jobKey = JobKey.jobKey(name, group);
			scheduler.pauseJob(jobKey);
			log.info("暂停作业=> [作业名称：" + name + " 作业组：" + group + "] ");
		} catch (SchedulerException e) {
			e.printStackTrace();
			log.error("暂停作业=> [作业名称：" + name + " 作业组：" + group + "]=> [失败]");
		}
	}

	/**
	 * 方法描述： 恢复任务
	 * @param name 任务名称
	 * @param group 任务组
	 * @return: void
	 */
	public void resumeJob(String name, String group) {
		try {
			JobKey jobKey = JobKey.jobKey(name, group);
			scheduler.resumeJob(jobKey);
			log.info("恢复作业=> [作业名称：" + name + " 作业组：" + group + "] ");
		} catch (SchedulerException e) {
			e.printStackTrace();
			log.error("恢复作业=> [作业名称：" + name + " 作业组：" + group + "]=> [失败]");
		}
	}

	/**
	 * 方法描述：修改任务表达式
	 * @param name 任务名称
	 * @param group 任务组
	 * @param cronExpression 任务表达式
	 * @return: void
	 */
	public void modifyTime(String name, String group, String cronExpression) {
		try {
			TriggerKey tk = TriggerKey.triggerKey(name, group);
			// 构造任务触发器
			Trigger trg = newTrigger().withIdentity(name, group)
					.withSchedule(cronSchedule(cronExpression)).build();
			scheduler.rescheduleJob(tk, trg);
			log.info("修改作业触发时间=> [作业名称：" + name + " 作业组：" + group + "] ");
		} catch (SchedulerException e) {
			e.printStackTrace();
			log.error("修改作业触发时间=> [作业名称：" + name + " 作业组：" + group + "]=> [失败]");
		}
	}

	/**
	 * 方法描述：启动任务
	 * @return: void
	 */
	public void startQuartz() {
		try {
			scheduler.start();
			log.info("启动调度器 ");
		} catch (SchedulerException e) {
			e.printStackTrace();
			log.error("启动调度器=> [失败]");
		}
	}

	/**
	 * 方法描述：停止任务
	 * @return: void
	 */
	public void shutdownQuartz() {
		try {
			scheduler.shutdown();
			log.info("停止调度器 ");
		} catch (SchedulerException e) {
			e.printStackTrace();
			log.error("停止调度器=> [失败]");
		}
	}
}
